package com.dx.chat.kafka.config.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * 消费者标记接口
 *
 * @author xufeng
 * @since 13.04.2023
 */
public interface IKafkaConsumerService {
    /**
     * 用户发送消息  持久化到数据库等逻辑
     * logic 模块监听
     * 服务器到服务器
     *
     * @param record s2s_chat = 发件箱
     */
    void dataPersistenceListener(ConsumerRecord<String, String> record);

    /**
     * 用户发送离线消息，持久化到mongodb
     * logic 模块监听
     * 服务器到 phsh
     *
     * @param record
     */
    void offlineMsgListener(ConsumerRecord<String, String> record);

    /**
     * Pusher 模块监听
     * s2m_chat = 收件箱
     *
     * @param record
     */
    void listenerPusher(ConsumerRecord<String, String> record);
}
